package com.boot.streamsend;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * StreamReceive   SinkSender   消息生产者  每两秒发送一条信息
 * StreamSend      SinkReceiver 消息消费者  接收消息
 *
 * 测试3： 消息驱动的微服务（消费组）
 * 开启 stream-receive（多个）、stream-send
 *
 * 测试4： 消息驱动的微服务（消息分区）
 * 开启 stream-receive（多个）、stream-send
 */
@SpringBootApplication
public class StreamSendApplication {

	public static void main(String[] args) {
		SpringApplication.run(StreamSendApplication.class, args);
	}
}
